/*Statement和PreparedStatement批量更新 
PreparedStatement：
 
1） addBatch()将一组参数添加到PreparedStatement对象内部。
 
2） executeBatch()将一批参数提交给数据库来执行，如果全部命令执行成功，则返回更新计数组成的数组。
 
Statement：
 
1） addBatch(String sql)方法会在批处理缓存中加入一条sql语句。
 
2） executeBatch()执行批处理缓存中的所有sql语句。
 
注意：PreparedStatement中使用批量更新时，要先设置好参数后再使用addBatch()方法加入缓存。批量更新中只能使用更改、删除或插入语句。

 */

package com.cfwx.db.jdbc;
import java.sql.Connection;  
import java.sql.SQLException;  
import java.sql.Statement;  
/* 
*1,首先把Auto commit设置为false,不让它自动提交 
9. *2,进行手动提交（commit） 
10. *3,提交完成后回复现场将Auto commit,还原为true, 
11. *4,当异常发生执行catch中SQLException时，记得要rollback(回滚)； 
12. * */  
public class StatementCommitAndRollbackTest {  
    public static void main(String args[]) {  
        Connection con = null;  
        Statement stm = null;  
        try {  
            con = JdbcUtil.getConnection();  
            stm = con.createStatement();  
            con.setAutoCommit(false);  
            // 若不出现异常，则继续执行到try语句完，否则跳转到catch语句中  
            stm.addBatch("insert into student values(23,'tangbao','100')");  
            stm.addBatch("insert into student values(24,'王定','98')");  
            stm.addBatch("insert into student values(25,'王国云','90')");  
            stm.addBatch("insert into student values(26,'溜出','89')");  
            stm.addBatch("insert into student values(27,'wqde','63')");  
            /* 
            * int[] executeBatch() throws 
            * SQLException将一批命令提交给数据库来执行，如果全部命令执行成功，则返回更新计数组成的数组。 
            */  
            stm.executeBatch();  
            System.out.println("插入成功!");  
            // commit:若成功执行完所有的插入操作，则正常结束  
            con.commit();  
            System.out.println("提交成功!");  
            con.setAutoCommit(true);  
  
        } catch (SQLException e) {  
            e.printStackTrace();  
            try {  
    //rollback: 若出现异常，对数据库中所有已完成的操作全部撤销，则回滚到事务开始状态  
                if (!con.isClosed()) {  
                    con.rollback();  
                    System.out.println("提交失败，回滚！");  
                    con.setAutoCommit(true);  
                }  
            } catch (SQLException e1) {  
                e1.printStackTrace();  
            } finally {  
                JdbcUtil.closeConnection(con);  
            }  
        }  
    }  
}  

